package com.kancy.demo.streamplus.channel.listener;

import com.kancy.demo.streamplus.channel.TestChanel;
import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.messaging.Message;
import org.springframework.stereotype.Component;

/**
 * <p>
 * DevChannelListener
 * <p>
 *
 * @author: kancy
 * @date: 2020/3/13 10:19
 **/
@Slf4j
@Component
public class TestChannelListener {

    @StreamListener(value = TestChanel.INPUT)
    public void receiveMessage(Message message){
        log.info("接受[TEST]消息：{}", message);
    }
}
